package com.boarsoft.message.rocketmq;

import com.boarsoft.message.bean.Message;
import com.boarsoft.message.rocketmq.converter.RocketMsgConverter;

public class RocketMQProducerEx extends RocketMQProducer {
	/** */
	protected RocketMsgConverter converter;

	public void put(Message msg) throws Exception {
		org.apache.rocketmq.common.message.Message m = converter.convert(msg);
		producer.send(m);
	}

	public RocketMsgConverter getConverter() {
		return converter;
	}

	public void setConverter(RocketMsgConverter converter) {
		this.converter = converter;
	}
}
